-
Notifications
You must be signed in to change notification settings - Fork 1.2k
Add some testcases and missing ASF headers for new scheduler #5243
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
80978b5
to
14678cf
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Great!
Codecov Report
@@ Coverage Diff @@
## master #5243 +/- ##
==========================================
+ Coverage 70.63% 75.20% +4.56%
==========================================
Files 238 238
Lines 13996 13996
Branches 561 561
==========================================
+ Hits 9886 10525 +639
+ Misses 4110 3471 -639
Continue to review full report at Codecov.
|
f0e2019
to
b5e9c91
Compare
I think this should fix some unstable tests in new scheduler |
val watcher = system.actorOf(WatcherService.props(mockEtcdClient)) | ||
|
||
val ns = NamespaceContainerCount(namespace, mockEtcdClient, watcher) | ||
Thread.sleep(1000) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I hope we avoid using this kind of waiting if possible.
Can we replace this with something like a reactive one?
It might cause some non-deterministic results of CI tests.
For example, we might periodically check the expected status during the given time limit with some interval.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
replaced with retry, but there are many Thread.sleep
in tests files, we may need an another pr to replace them
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Agree.
I just wanted not to add more Thread.sleep
.
2769d89
to
dee36e6
Compare
…5243) * Add some testcases and missing ASF headers for new scheduler * Reset stream after each test * Wait more time * Update msg start time to ensure it's not stale * Make MemoryQueueFlowTests stable * Ignore warmUp msg immediately * Use retry to replace sleep * Add missing config * Fix configuration error
Add some testcases&missing ASF headers
Description
Related issue and scope
My changes affect the following components
Types of changes
Checklist: